package project.base;

import java.io.Serializable;
import java.lang.reflect.Method;

import org.apache.logging.log4j.LogManager;

import common.db.JdbcSource;
import common.db.dao.Dao;
import common.db.dao.DaoConstraintException;
import common.db.dao.DaoLockException;
import common.db.dao.DaoUtil;

import core.config.Factory;

/**
 * 更新サービス親クラス
 *
 * @author Tadashi Nakayama
 * @version 1.0.0
 */
public abstract class UpdateAbstract extends QueryAbstract {

	/** バージョン */
	private String versionName = "Version";
	/** 作成者ID */
	private String creatorName = "InsertId";
	/** 作成日時 */
	private String createdName = "InsertDatetime";
	/** 更新者ID */
	private String updaterName = "UpdateId";
	/** 更新日時 */
	private String updatedName = "UpdateDatetime";

	/**
	 * バージョン名設定
	 * @param val バージョン名
	 */
	protected final void setVersionName(final String val) {
		this.versionName = val;
	}

	/**
	 * 作成者ID名設定
	 * @param val 作成者ID名
	 */
	protected final void setCreatorName(final String val) {
		this.creatorName = val;
	}

	/**
	 * 作成日時名設定
	 * @param val 作成日時
	 */
	protected final void setCreatedName(final String val) {
		this.createdName = val;
	}

	/**
	 * 更新者ID名設定
	 * @param val 更新者ID
	 */
	protected final void setUpdaterName(final String val) {
		this.updaterName = val;
	}

	/**
	 * 更新日時名設定
	 * @param val 更新日時名
	 */
	protected final void setUpdatedName(final String val) {
		this.updatedName = val;
	}

	/**
	 * シーケンス取得
	 * @param name シーケンス名
	 * @return シーケンス
	 */
	protected final long getSequence(final String name) {
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.sequence(name);
		}
	}

	/**
	 * 排他検索処理
	 * @param <T> ジェネリックス
	 *
	 * @param cls クラス
	 * @param id ID
	 * @return レコードが不在の場合 null を返す。
	 */
	protected final <T> T find(final Class<T> cls, final Serializable id) {
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.findById(cls, id);
		}
	}

	/**
	 * 排他検索処理
	 * @param <T> ジェネリックス
	 *
	 * @param cls クラス
	 * @param id ID
	 * @return レコードが不在の場合 null を返す。
	 */
	protected final <T> T findWithLock(final Class<T> cls, final Serializable id) {
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.findByIdWithLock(cls, id);
		} catch (DaoLockException ex) {
			LogManager.getLogger().warn(ex.getMessage());
			return null;
		}
	}

	/**
	 * 作成処理
	 *
	 * @param obj 保存オブジェクト
	 */
	protected final void insert(final Serializable obj) {
		setVersion(obj, 1);
		setUpdateInfo(obj);
		setCreateInfo(obj);
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			dao.insert(obj);
		}
	}

	/**
	 * 更新処理
	 *
	 * @param obj 更新オブジェクト
	 * @return 他で更新されていた場合 false を返す。
	 */
	protected final boolean update(final Serializable obj) {
		countup(obj);
		setUpdateInfo(obj);
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.update(obj);
		} catch (DaoConstraintException ex) {
			if (!ex.isNoWait()) {
				throw ex;
			}
			LogManager.getLogger().warn(ex.getMessage());
			return false;
		}
	}

	/**
	 * 物理削除処理
	 *
	 * @param obj 削除オブジェクト
	 * @return 他で更新されていた場合 false を返す。
	 */
	protected final boolean delete(final Serializable obj) {
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.delete(obj);
		}
	}

	/**
	 * 論理削除処理
	 *
	 * @param obj 削除オブジェクト
	 * @return 他で更新されていた場合 false を返す。
	 */
	protected final boolean invisible(final Serializable obj) {
		setVersion(obj, 0);
		setUpdateInfo(obj);
		try (Dao dao = JdbcSource.getDao(super.getSchema())) {
			return dao.update(obj);
		} catch (DaoConstraintException ex) {
			if (!ex.isNoWait()) {
				throw ex;
			}
			LogManager.getLogger().warn(ex.getMessage());
			return false;
		}
	}

	/**
	 * カウントアップ
	 * @param obj 更新オブジェクト
	 */
	protected final void countup(final Serializable obj) {
		Number num = (Number)DaoUtil.getValue(obj, this.versionName);
		if (num.intValue() == 999999) {
			setVersion(obj, 1);
		} else {
			setVersion(obj, num.intValue() + 1);
		}
	}

	/**
	 * 更新可能確認
	 * @param obj 更新オブジェクト
	 * @param ver バージョン
	 * @return 更新可能の場合 true を返す。
	 */
	protected final boolean isUpdatable(final Serializable obj, final Number ver) {
		if (obj != null) {
			Object val = DaoUtil.getValue(obj, this.versionName);
			if (val == null && ver == null) {
				return true;
			} else if (val != null && ver != null) {
				int v = ((Number)val).intValue();
				return ver.intValue() == v;
			}
		}
		return false;
	}

	/**
	 * 作成情報設定
	 *
	 * @param obj オブジェクト
	 */
	protected final void setCreateInfo(final Object obj) {
		String uid = super.getUid();
		if (uid == null) {
			uid = Factory.getClassBaseName(this.getClass());
		}
		setObject(obj, this.creatorName, uid);
		setObject(obj, this.createdName, super.getDateTime());
	}

	/**
	 * 更新情報設定
	 *
	 * @param obj オブジェクト
	 */
	protected final void setUpdateInfo(final Object obj) {
		String uid = super.getUid();
		if (uid == null) {
			uid = Factory.getClassBaseName(this.getClass());
		}
		setObject(obj, this.updaterName, uid);
		setObject(obj, this.updatedName, super.getDateTime());
	}

	/**
	 * バージョン設定
	 * @param obj オブジェクト
	 * @param val バージョン番号
	 */
	protected final void setVersion(final Object obj, final int val) {
		setObject(obj, this.versionName, Integer.valueOf(val));
	}

	/**
	 * 値設定
	 *
	 * @param obj オブジェクト
	 * @param m 項目名
	 * @param val 値
	 */
	protected final void setObject(final Object obj, final String m, final Object val) {
		Class<?> cls = obj.getClass();
		Method get = Factory.getMethod(cls, "get" + m);
		if (get != null) {
			Method set = Factory.getMethod(cls, "set" + m, get.getReturnType());
			Factory.invoke(obj, set, val);
		}
	}
}
